package com.juyu.miliao.scheduler.service;

import com.juyu.miliao.common.delay.DelayMessage;

import java.util.concurrent.DelayQueue;

/**
 * @author xuanqicheng
 */
public interface VipExpireService {
    /**
     * 初始化队列
     * @return
     */
    DelayQueue<DelayMessage> getVipExpireQueueInit();

    /**
     * 添加消息
     * @param delayMessage
     */
    void putDelayMessage(DelayMessage delayMessage);

    /**
     * 处理过期vip
     * @param take
     * @throws Exception
     */
    void vipExpireDataHandler(DelayMessage<Integer> take) throws Exception;
}
